package com.xiawu;

import java.io.*;
import java.net.Socket;
import java.util.Scanner;

// 客户端聊天
public class ClientWX {
    public static void main(String[] args) throws  Exception {
      // 1，创建客户端对象
      Socket client = new Socket("127.0.0.1",9000);
        System.out.println("--------------客户端--------------");
      // 2，开启链接通道 【把输入输出流字节流转为 对应的  字符输出输出流】
      /*  OutputStream out = client.getOutputStream(); // 字节流
        OutputStreamWriter osw = new OutputStreamWriter(out); // 字符字节中间流
        BufferedWriter bw = new BufferedWriter(osw);    // 字符流*/
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
        BufferedReader br = new BufferedReader(new InputStreamReader(client.getInputStream()));
       // 3,客户端先发送语句，然后再接收服务给出的回复
      // 无限聊天 ---  无限次的聊天
       while(true){
         Scanner sc = new Scanner(System.in);
         System.out.println("请说话");
         String s = sc.next();
         bw.write(s); // 如果没有关闭，则信息滞留在通道内；
         bw.newLine();
         bw.flush();  // 刷新通道，让通道的数据到达目的点
         if(s.equals("byebye")){  // 终止聊天的方式
           break;
         }
         String s2 = br.readLine();
         System.out.println("服务说："+ s2);
       }

       // 4,释放资源
        br.close();
        bw.close();
        client.close();

    }
}
